//package com.fecean.aabbc.netty.server.prod1;
//
//import com.fecean.aabbc.netty.server.init.ClientChannel;
//import io.netty.channel.ChannelHandler;
//import io.netty.channel.ChannelHandlerContext;
//import io.netty.channel.ChannelInboundHandlerAdapter;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.stereotype.Component;
//
//import javax.annotation.Resource;
//import java.util.Objects;
//
///**
// * NettyServerHeartBeatHandler
// *
// * @author: chenfenghai
// * @version: 1.0
// * @date: 2020-03-05 15:59
// * @blame Team
// */
//@Slf4j
//@Component
//@ChannelHandler.Sharable
//public class NettyServerRegisterHandler extends ChannelInboundHandlerAdapter {
//
//    @Resource
//    private ClientChannel clientChannel;
//
//    @Override
//    public void channelActive(ChannelHandlerContext ctx) throws Exception {
//        log.info("客户端已经连接");
//        ctx.fireChannelActive();
//    }
//
//    @Override
//    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
//        if(Objects.equals("客户端注册", msg)){
//            log.info("服务器收到信息：{}", msg);
//            ctx.channel().writeAndFlush("注册完成");
//            clientChannel.saveClientChannel("abc", ctx.channel());
//            log.info("服务器连接数量：{}", clientChannel.getSize());
//        }else{
//            ctx.fireChannelRead(msg);
//        }
//    }
//
//    @Override
//    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
//        log.info("客户端已经退出");
//        clientChannel.removeClientChannel(ctx.channel());
//        log.info("服务器连接数量：{}", clientChannel.getSize());
//        ctx.fireChannelInactive();
//    }
//}
